feed189beb1af96b257ef85b43ffcf394f554eb6,metacat-user-metadata-mysql/src/main/java/com/netflix/metacat/usermetadata/mysql/MysqlUserMetadataService.java,MysqlUserMetadataService,_deleteDataMetadatas,#Connection#List#,198
Before Change
List<String> paramVariables = uris.stream().map(s -> "?").collect(Collectors.toList());
String[] aUris = uris.stream().toArray(String[]::new);
String paramString = Joiner.on(",").skipNulls().join(paramVariables);
new QueryRunner().update(conn,
String.format(SQL.DELETE_DATA_METADATA, paramString), (Object[]) aUris);
new QueryRunner().update(conn,
String.format(SQL.DELETE_DATA_METADATA_DELETE, paramString), (Object[]) aUris);
}
After Change
String[] aUris = uris.stream().toArray(String[]::new);
String paramString = Joiner.on(",").skipNulls().join(paramVariables);
ColumnListHandler<Long> handler = new ColumnListHandler<>("id");
List<Long> ids = new QueryRunner().query( conn,
String.format(SQL.GET_DATA_METADATA_IDS, paramString), handler, (Object[]) aUris);
if( !ids.isEmpty()) {
List<String> idParamVariables = ids.stream().map(s -> "?").collect(Collectors.toList());
Long[] aIds = ids.stream().toArray(Long[]::new);